google.golang.org/grpc.serverStream.s (field)

20 uses

	google.golang.org/grpc (current package)
		server.go#L1598: 		s:                     stream,
		server.go#L1685: 			ss.s.WriteStatus(st)
		server.go#L1747: 				Trailer: ss.s.Trailer(),
		server.go#L1754: 		ss.s.WriteStatus(appStatus)
		server.go#L1765: 			Trailer: ss.s.Trailer(),
		server.go#L1772: 	return ss.s.WriteStatus(statusOK)
		stream.go#L1586: 	s     *transport.ServerStream
		stream.go#L1630: 	return ss.s.SetHeader(md)
		stream.go#L1639: 	err = ss.s.SendHeader(md)
		stream.go#L1641: 		h, _ := ss.s.Header()
		stream.go#L1660: 	ss.s.SetTrailer(md)
		stream.go#L1679: 			ss.s.WriteStatus(st)
		stream.go#L1691: 	if sendCompressorsName := ss.s.SendCompress(); sendCompressorsName != ss.sendCompressorName {
		stream.go#L1718: 	if err := ss.s.Write(hdr, payload, &transport.WriteOptions{Last: false}); err != nil {
		stream.go#L1724: 			h, _ := ss.s.Header()
		stream.go#L1742: 			sh.HandleRPC(ss.s.Context(), outPayload(false, m, dataLen, payloadLen, time.Now()))
		stream.go#L1764: 			ss.s.WriteStatus(st)
		stream.go#L1778: 	if err := recv(ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, payInfo, ss.decompressorV1, true); err != nil {
		stream.go#L1800: 			sh.HandleRPC(ss.s.Context(), &stats.InPayload{
		stream.go#L1824: 	if err := recv(ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, nil, ss.decompressorV1, true); err == io.EOF {

The pages are generated with Golds v0.7.6. (GOOS=linux GOARCH=amd64)